package com.yq.db;

import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DBDriver {
	
	/**
	 * 获取数据库连接对象
	 * @return
	 */
	public Connection getConn(){
		Connection conn =null;
		try{
			//注册驱动
			//读取数据库的配置文件
			InputStream is=this.getClass().getClassLoader().getResourceAsStream("db.properties");
			//创建java.util 包中的工具类
			Properties prop =new Properties();
			//加载被读取的文件
			prop.load(is);
			//数据库驱动类型
			String dbDriverType=prop.getProperty("dbDriverType");
			String dbURL=prop.getProperty("dbURL");
			String dnUser=prop.getProperty("dbUser");
			String dbPSW=prop.getProperty("dbPSW");
			Class.forName(dbDriverType).newInstance();
		}catch(Exception e){
			System.out.println("连接异常");
			e.printStackTrace();
		}
		return conn;
	}

	public ResultSet query(String strSql){
		ResultSet rs=null;
		try{
			Statement st =getConn().createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_UPDATABLE);
			rs=st.executeQuery(strSql);
		}catch(Exception e){
			System.out.println("链接异常");
			e.printStackTrace();
		}
		return rs;
	}
	
	public void closeConn(Connection conn){
		try{
			if(conn!=null){
				conn.close();
			}
		}catch(SQLException e){
			System.out.println("数据库连接异常");
			e.printStackTrace();
		}
	}


}
